// 导入MySQL模块
var mysql = require('mysql');
var dbConfig = require('../db/DBConfig');
var userSQL = require('../db/UserSQL');
// 使用DBConfig.js的配置信息创建一个MySQL连接池
var pool = mysql.createPool( dbConfig.mysql );

// 用户验证接口
function w_user_login(values) {
    return new Promise((resolve,reject) => {
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.w_user_login,values, (err, rows) => {
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有登陆结果');
                        }else {
                            resolve(rows);
                            console.log(rows,'无用户结果');
                        }
                    }
                    // 释放连接
                    connection.release();
                })
            }
        })
    })
};
// 客服登陆接口
function w_service_login(a,b){
    return new Promise((resolve,reject) => {
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.w_service_login,[a,b], (err, rows) => {
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有找到用户返回密码');
                        }else {
                            resolve(rows);
                            console.log(rows,'未找到用户返回空包');
                        }
                    }
                    // 释放连接
                    connection.release();
                })
            }
        })
    })
};
// 写入聊天记录到数据库 (不需要回调 所以不用异步)
function w_write_chat_record(a,b,c) {
    pool.getConnection(function(err, connection) {
        connection.query(userSQL.w_write_chat_record,[a,b,c], (err, rows) => {
            if (err) {
                console.log(err,'报错');
            } else {
                console.log(rows,'写入成功');
            }
            // 释放连接
            connection.release();
        })
    })
}
// 读取数据库的聊天记录
function w_get_chat_records(a,b,c) {
    return new Promise((resolve,reject) => {
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.w_service_login,[a,b,c], (err, rows) => {
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有找到聊天记录');
                        }else {
                            resolve(rows);
                            console.log(rows,'未找到聊天记录');
                        }
                    }
                    // 释放连接
                    connection.release();
                })
            }
        })
    })
}
module.exports = {w_user_login,w_service_login,w_write_chat_record,w_get_chat_records};